package com.yanyeori.framework.redis.listener;

/**
 * redis订阅消费者
 *
 * @author chenkuan 2020/08/17
 */
public abstract class RedisListener<T> {
    protected final String topic;

    public RedisListener(String topic) {
        this.topic = topic;
    }

    protected abstract void receive(T message);
}
